package com.yjzx.util.binlog.core.config;

import com.yjzx.util.binlog.core.entiry.recordIndex.BinaryLogClientIndex;
import com.yjzx.util.binlog.core.entiry.Conf;
import lombok.Getter;
import lombok.Setter;

import java.util.Map;
import java.util.Set;

/**
 * @author yjzx
 * @date 2024/9/20
 * @description BinLogBean
 */
@Getter
@Setter
public class BinLogBean {
    /**
     * 数据源配置
     */
    private Conf datasource;
    /**
     * 数据库和表名配置
     */
    private Map<String, String> dbTable;

    private BinaryLogClientIndex readBinLogIndex;
    private Set<BinaryLogClientIndex> writeBinLogIndex;

    public int coreThreads = 2;
    public int consumerThreads = 5;

}
